from multi_agent import AutonomousCoordinator
import sys

class MarketingAnalyticsSystem:
    """全自主市场营销分析系统"""
    
    def __init__(self):
        self.coordinator = AutonomousCoordinator()
        
    def run(self):
        """运行全自主分析系统"""
        print("=== 全自主市场营销分析系统 ===")
        print("系统启动中...")
        self.coordinator.start_agents()
        
        try:
            # 自动检测并分析数据
            print("\n检测到数据文件，开始分析...")
            self.coordinator.analyze_data('sample_data.csv')
            
            # 持续监控新数据
            print("\n进入持续监控模式...")
            while True:
                self.coordinator.monitor_new_data()
                time.sleep(60)  # 每分钟检查一次新数据
                
        except KeyboardInterrupt:
            print("\n接收到终止信号，停止系统...")
        finally:
            self.coordinator.stop_agents()

def main():
    """主程序入口"""
    system = MarketingAnalyticsSystem()
    system.run()


if __name__ == "__main__":
    main()